package com.java1412.interceptor;

import com.hazelcast.core.Message;
import com.hazelcast.core.MessageListener;

/**
 * @author java1412
 * @create 2021-07-12 17:14
 */
public class TopicListener implements MessageListener<String> {
    @Override
    public void onMessage(Message<String> message) {
        String msg = message.getMessageObject();
        System.out.println("收到Topic消息：" + msg);
    }
}
